/**
 * 任务流执行器.
 */
package com.cnpc.bds.sdk.sink.kafka.executor;